package com.yusvn.scm.goods.base.service;

import com.alibaba.fastjson.JSON;
import com.jfinal.kit.Kv;
import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Page;
import com.jfinal.plugin.activerecord.Record;
import com.yusvn.scm.common.BaseService;
import com.yusvn.scm.common.constant.Const;
import com.yusvn.scm.common.kit.RetKit;
import com.yusvn.scm.common.model.ScmPzbh;

import java.util.List;

public class ScmPzbhService extends BaseService {
            ScmPzbh dao = new ScmPzbh().dao();

    public Page<ScmPzbh> selectPzbhList(Kv kv){

        Page<ScmPzbh> pzbhList = dao.template("scmPzbh.page",kv).paginate(getPage(kv),getLimit(kv));
            return pzbhList;
    }

    public RetKit addPzbh(String jsonObj){

        ScmPzbh scmPzbh = JSON.parseObject(jsonObj,ScmPzbh.class);
        long id = Db.use(Const.SCMDB).queryLong("select nvl(max(id),0)+1 cnt from scm_pzbh ");
        scmPzbh.setId(id); //查询最大ID oracle不支持自增ID
        if (scmPzbh.use(Const.SCMDB).save()){
            return RetKit.ok("新增成功");
        }
        return RetKit.fail("新增失败");
    }

    public RetKit updatePzbh(String jsonObj){

        ScmPzbh scmPzbh = JSON.parseObject(jsonObj,ScmPzbh.class);
        if (scmPzbh.use(Const.SCMDB).update()){
            return RetKit.ok("修改成功");
        }
        return RetKit.fail("修改失败");
    }

    public RetKit deletePzbh(String id){


        if (dao.deleteById(id)){
            return RetKit.ok("删除成功");
        }
        return RetKit.fail("删除失败");
    }

    public List<Record> selectAll(){
        List<Record> records = Db.use(Const.SCMDB).find("select * from scm_pzbh");
            return records;
    }

}
